package com.itjcloud.iot.gateway.client;


import com.itjcloud.iot.gateway.model.CheckSignResultDTO;
import com.itjcloud.iot.gateway.model.Result;
import org.springframework.core.io.buffer.DataBuffer;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.service.annotation.PostExchange;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

/**
 * 调用物联网中台的接口
 */

public interface IotClient {


    @PostExchange("/device/checkSignature")
    Mono<Result<CheckSignResultDTO>> postResource(
            @RequestParam("deviceId") String deviceId,
            @RequestParam("signature") String signature,
            @RequestBody Flux<DataBuffer> body);


}
